package cn.xinfei.xdecision.pulsar.consumer;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface XPulsarConsumerAnnotate {

    String topic();

    Class clazz() default String.class;//暂不实现

    String consumerName();

    String subscriptionName();

    String concurrent() default "1";

    boolean batch() default false;
}
